package test2

import org.apache.spark.{SparkConf, SparkContext}

object demo2 {
  def main(args: Array[String]): Unit = {
    // 创建 SparkConf 和 SparkContext 对象
    var conf = new SparkConf().setAppName("myapp").setMaster("local")
    var sc = new SparkContext(conf)

    var al = Array(3,4,5,6,7)
    // 累加求和
    val sum1 =  al.reduceLeft((x,y) => x+y)
    val sum2 = al.foldLeft(0)((x,y) => x+y) // "0" -> 初始值
    println(sum1,sum2)

    /*结果：(25, 25)*/

//    var add1 = sc.longAccumulator(name = "mytest")
//    var rdd1 = sc.makeRDD(al)
//    rdd1.foreach(x => add1.add(x))
  }
}
